package com.lmn.stream.kafka;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;

@SpringBootApplication
@EnableBinding({Sink.class, Source.class})
public class RocketMQApplication {

    private static final Logger LOG = LoggerFactory.getLogger(RocketMQApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(RocketMQApplication.class, args);
        LOG.info("启动成功");
    }

}
